package com.hzh.spark.core

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

object Demo24PageRank {

  def main(args: Array[String]): Unit = {
    /**
     * 1、创建连接
     */
    val conf = new SparkConf()
    conf.setAppName("Demo24PageRank")
    conf.setMaster("local")
    val sc = new SparkContext(conf)
    val dataRDD: RDD[String] = sc.textFile("data/PageRank.txt")
    dataRDD.map(line=>{
      val split: Array[String] = line.split("-")
      split
    })





  }
}
